# -*- coding: utf-8 -*-
from datetime import timedelta

from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor

jms_dwd__dwd_third_package_list_base_hi_05 = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dwd__dwd_third_package_list_base_hi_05",
    filepath='/dw/hive/jms_dwd.db/external/dwd_third_package_list_base_hi/',
    execution_timeout=timedelta(minutes=15),
    email=['shenjiaming@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)
